//
// Created by pengtg on 2020/2/22.
//

#include "IDemux.h"
#include "XLog.h"

void IDemux::Main()
{
    while (!isExit)
    {
        /*IDemux来负责具体的解码的业务逻辑的实现，
         * 和具体的实现由FFDemux来做，二者分开
         * 后续如果换成其他的具体解码实现，IDemux中调用都无需修改
        */
        if(IsPause())
        {
            XSleep(2);
            continue;
        }
         XData d = Read();
         if(d.size > 0)
             Notify(d);//通知所有观察者
         else
             XSleep(2);
        //XLOGI("IDemux Read %d",d.size);
        //if(d.size <= 0) break;
    }
}